/*
 * @Description: 
 * @Author: changqing
 * @Date: 2021-08-29 19:58:41
 * @LastEditTime: 2021-08-29 19:59:46
 * @LastEditors: changqing
 * @Usage: 
 */

//看名字应该不难理解，用来让整个Observable发生错误用的。因此订阅时要记得使用error来处理，同时当有错误发生时，就不会有complete发生
// throwError一般不会单独使用，而是在使用pipe设计整个Observable时，用来处理错误的

var {throwError } = require('rxjs');
const source = throwError("这是一个错误消息");
  source.subscribe({
  next: (data) => console.log(`throwError 示例 (next): ${data}`),
  error: (error) => console.log(`throwError 示例 (error): ${error}`),
  complete: () => console.log("throwError 示例 (complete)"),
});
// throwError 示例 (error): 这是一个错误消息      